package com.holly.unit.kafka.model;

import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;

/**
 * 批次获取kafka消息的回调函数
 * @author pengpeng
 *
 */
@FunctionalInterface
public interface CallbackReceiveMessage {
	
	/**
	 * 回调获取消息列表
	 * @param messageList  获取的消息列表，可能为空消息
	 * @param kafkaConsumer 手动提交偏移量
	 * @param isNoStop 默认true  false:停止获取消息
	 */
	void receiveMessage(List<Kmessage> messageList,Object kafkaConsumer,AtomicBoolean isNoStop);

}
